const mysql = require('mysql');

//配置连接
const connection = {
    host: 'localhost',
    post: '3306',
    user: 'root',
    password: 'jianpan',
    // database: 'test_react_03'
    database: 'commonsql'

};

// // 创建连接对象
// let con = mysql.createConnection(connection);

// // 连接
// con.connect(err => {
//     if (err) {
//         console.log('数据库连接失败');
//     } else {
//         console.log('数据库连接成功');
//     }
// });

//创建promise对象查询方法

function queryFn(sqlStr, arr) {
    //创建连接对象
    let con = mysql.createConnection(connection);
    return new Promise((resolve, reject) => {
        con.query(sqlStr, arr, (error, result) => {
            if (error) {
                reject(error);
            } else {
                resolve(result);
                con.end()
            }
        });
    });
}

module.exports = queryFn;